Support Streaming service

Author: ccushing

CHANGELOG.md

@@ -1,8 +1,9 @@
-## 3.15.1 (Unreleased)
-Enable regional Subnets by making Availability Domain optional when creating a Subnet
+## 3.16.0 (Unreleased)
 
 ### Added
 - Adding description property to rules in Steering Policies in DNS
+- Enable regional Subnets by making Availability Domain optional when creating a Subnet
+- Support for Streaming service
 
 ### Fixed
 - DNS Record now requires domain and rtype as mandatory arguments. Managing DNS record resources now requires DNS_RECORD* level policy entitlements instead of DNS_ZONE*. [Permissions List](https://docs.cloud.oracle.com/iaas/Content/Identity/Reference/dnspolicyreference.htm) 

docs/examples/streaming/main.tf

@@ -0,0 +1,56 @@
+variable "tenancy_ocid" {}
+variable "user_ocid" {}
+variable "fingerprint" {}
+variable "private_key_path" {}
+variable "region" {}
+
+provider "oci" {
+  tenancy_ocid     = "${var.tenancy_ocid}"
+  user_ocid        = "${var.user_ocid}"
+  fingerprint      = "${var.fingerprint}"
+  private_key_path = "${var.private_key_path}"
+  region           = "${var.region}"
+}
+
+resource "oci_streaming_stream" "stream" {
+  compartment_id     = "${var.tenancy_ocid}"
+  name               = "stream1"
+  partitions         = "1"
+  retention_in_hours = "24"
+}
+
+data "oci_streaming_stream" "stream1" {
+  stream_id = "${oci_streaming_stream.stream.id}"
+}
+
+# Output the result
+output "stream" {
+  value = <<EOF
+
+  id = "${data.oci_streaming_stream.stream1.id}"
+  compartment_id = "${data.oci_streaming_stream.stream1.compartment_id}"
+  messages_endpoint = "${data.oci_streaming_stream.stream1.messages_endpoint}"
+  name = "${data.oci_streaming_stream.stream1.name}"
+  partitions = "${data.oci_streaming_stream.stream1.partitions}"
+  retention_in_hours = "${data.oci_streaming_stream.stream1.retention_in_hours}"
+  state = "${data.oci_streaming_stream.stream1.state}"
+  time_created = "${data.oci_streaming_stream.stream1.time_created}"
+EOF
+
+  # This value is not always present--when state is FAILED it may contain an explanation.
+  #lifecycle_state_details = "${data.oci_streaming_stream.stream1.lifecycle_state_details}"
+}
+
+data "oci_streaming_streams" "streams" {
+  compartment_id = "${oci_streaming_stream.stream.compartment_id}"
+
+  # optional
+  state = "ACTIVE"
+
+  //  id    = "${oci_streaming_stream.stream.id}"
+  //  name  = "${oci_streaming_stream.stream.name}"
+}
+
+output "streams" {
+  value = "${data.oci_streaming_streams.streams.streams}"
+}

oci/provider.go

@@ -316,6 +316,13 @@ func dataSourcesMap() map[string]*schema.Resource {
 		"oci_file_storage_file_systems":                  FileStorageFileSystemsDataSource(),
 		"oci_file_storage_mount_targets":                 FileStorageMountTargetsDataSource(),
 		"oci_file_storage_snapshots":                     FileStorageSnapshotsDataSource(),
+		"oci_health_checks_http_monitor":                 HealthChecksHttpMonitorDataSource(),
+		"oci_health_checks_http_monitors":                HealthChecksHttpMonitorsDataSource(),
+		"oci_health_checks_ping_monitor":                 HealthChecksPingMonitorDataSource(),
+		"oci_health_checks_ping_monitors":                HealthChecksPingMonitorsDataSource(),
+		"oci_health_checks_http_probe_results":           HealthChecksHttpProbeResultsDataSource(),
+		"oci_health_checks_ping_probe_results":           HealthChecksPingProbeResultsDataSource(),
+		"oci_health_checks_vantage_points":               HealthChecksVantagePointsDataSource(),
 		"oci_identity_api_keys":                          IdentityApiKeysDataSource(),
 		"oci_identity_auth_tokens":                       IdentityAuthTokensDataSource(),
 		"oci_identity_availability_domains":              IdentityAvailabilityDomainsDataSource(),
@@ -372,13 +379,8 @@ func dataSourcesMap() map[string]*schema.Resource {
 		"oci_objectstorage_objects":                      ObjectStorageObjectsDataSource(),
 		"oci_objectstorage_preauthrequest":               ObjectStoragePreauthenticatedRequestDataSource(),
 		"oci_objectstorage_preauthrequests":              ObjectStoragePreauthenticatedRequestsDataSource(),
-		"oci_health_checks_http_monitor":                 HealthChecksHttpMonitorDataSource(),
-		"oci_health_checks_http_monitors":                HealthChecksHttpMonitorsDataSource(),
-		"oci_health_checks_ping_monitor":                 HealthChecksPingMonitorDataSource(),
-		"oci_health_checks_ping_monitors":                HealthChecksPingMonitorsDataSource(),
-		"oci_health_checks_http_probe_results":           HealthChecksHttpProbeResultsDataSource(),
-		"oci_health_checks_ping_probe_results":           HealthChecksPingProbeResultsDataSource(),
-		"oci_health_checks_vantage_points":               HealthChecksVantagePointsDataSource(),
+		"oci_streaming_stream":                           StreamingStreamDataSource(),
+		"oci_streaming_streams":                          StreamingStreamsDataSource(),
 	}
 }
 
@@ -448,6 +450,10 @@ func resourcesMap() map[string]*schema.Resource {
 		"oci_file_storage_file_system":              FileStorageFileSystemResource(),
 		"oci_file_storage_mount_target":             FileStorageMountTargetResource(),
 		"oci_file_storage_snapshot":                 FileStorageSnapshotResource(),
+		"oci_health_checks_http_monitor":            HealthChecksHttpMonitorResource(),
+		"oci_health_checks_ping_monitor":            HealthChecksPingMonitorResource(),
+		"oci_health_checks_http_probe":              HealthChecksHttpProbeResource(),
+		"oci_health_checks_ping_probe":              HealthChecksPingProbeResource(),
 		"oci_identity_api_key":                      IdentityApiKeyResource(),
 		"oci_identity_auth_token":                   IdentityAuthTokenResource(),
 		"oci_identity_compartment":                  IdentityCompartmentResource(),
@@ -485,10 +491,7 @@ func resourcesMap() map[string]*schema.Resource {
 		"oci_objectstorage_object":                  ObjectStorageObjectResource(),
 		"oci_objectstorage_namespace_metadata":      ObjectStorageNamespaceMetadataResource(),
 		"oci_objectstorage_preauthrequest":          ObjectStoragePreauthenticatedRequestResource(),
-		"oci_health_checks_http_monitor":            HealthChecksHttpMonitorResource(),
-		"oci_health_checks_ping_monitor":            HealthChecksPingMonitorResource(),
-		"oci_health_checks_http_probe":              HealthChecksHttpProbeResource(),
-		"oci_health_checks_ping_probe":              HealthChecksPingProbeResource(),
+		"oci_streaming_stream":                      StreamingStreamResource(),
 	}
 }
 

oci/provider_clients.go

@@ -23,6 +23,7 @@ import (
 	oci_kms "github.com/oracle/oci-go-sdk/keymanagement"
 	oci_load_balancer "github.com/oracle/oci-go-sdk/loadbalancer"
 	oci_object_storage "github.com/oracle/oci-go-sdk/objectstorage"
+	oci_streaming "github.com/oracle/oci-go-sdk/streaming"
 
 	oci_common "github.com/oracle/oci-go-sdk/common"
 )
@@ -98,6 +99,10 @@ func setGoSDKClients(clients *OracleClients, officialSdkConfigProvider oci_commo
 	if err != nil {
 		return
 	}
+	streamAdminClient, err := oci_streaming.NewStreamAdminClientWithConfigurationProvider(officialSdkConfigProvider)
+	if err != nil {
+		return
+	}
 	virtualNetworkClient, err := oci_core.NewVirtualNetworkClientWithConfigurationProvider(officialSdkConfigProvider)
 	if err != nil {
 		return
@@ -246,6 +251,10 @@ func setGoSDKClients(clients *OracleClients, officialSdkConfigProvider oci_commo
 	if err != nil {
 		return
 	}
+	err = configureClient(&streamAdminClient.BaseClient)
+	if err != nil {
+		return
+	}
 	err = configureClient(&virtualNetworkClient.BaseClient)
 	if err != nil {
 		return
@@ -267,6 +276,7 @@ func setGoSDKClients(clients *OracleClients, officialSdkConfigProvider oci_commo
 	clients.kmsVaultClient = &kmsVaultClient
 	clients.loadBalancerClient = &loadBalancerClient
 	clients.objectStorageClient = &objectStorageClient
+	clients.streamAdminClient = &streamAdminClient
 	clients.virtualNetworkClient = &virtualNetworkClient
 
 	return
@@ -289,6 +299,7 @@ type OracleClients struct {
 	kmsVaultClient          *oci_kms.KmsVaultClient
 	loadBalancerClient      *oci_load_balancer.LoadBalancerClient
 	objectStorageClient     *oci_object_storage.ObjectStorageClient
+	streamAdminClient       *oci_streaming.StreamAdminClient
 	virtualNetworkClient    *oci_core.VirtualNetworkClient
 	configuration           map[string]string
 }

oci/streaming_stream_data_source.go

@@ -0,0 +1,148 @@
+// Copyright (c) 2017, 2019, Oracle and/or its affiliates. All rights reserved.
+
+package provider
+
+import (
+	"context"
+
+	"github.com/hashicorp/terraform/helper/schema"
+	oci_streaming "github.com/oracle/oci-go-sdk/streaming"
+)
+
+func StreamingStreamDataSource() *schema.Resource {
+	return &schema.Resource{
+		Read: readSingularStreamingStream,
+		Schema: map[string]*schema.Schema{
+			"stream_id": {
+				Type:     schema.TypeString,
+				Required: true,
+			},
+			// Computed
+			"compartment_id": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+			"defined_tags": {
+				Type:     schema.TypeMap,
+				Computed: true,
+				Elem:     schema.TypeString,
+			},
+			"freeform_tags": {
+				Type:     schema.TypeMap,
+				Computed: true,
+				Elem:     schema.TypeString,
+			},
+			"lifecycle_state_details": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+			"messages_endpoint": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+			"name": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+			"partitions": {
+				Type:     schema.TypeInt,
+				Computed: true,
+			},
+			"retention_in_hours": {
+				Type:     schema.TypeInt,
+				Computed: true,
+			},
+			"state": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+			"time_created": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+		},
+	}
+}
+
+func readSingularStreamingStream(d *schema.ResourceData, m interface{}) error {
+	sync := &StreamingStreamDataSourceCrud{}
+	sync.D = d
+	sync.Client = m.(*OracleClients).streamAdminClient
+
+	return ReadResource(sync)
+}
+
+type StreamingStreamDataSourceCrud struct {
+	D      *schema.ResourceData
+	Client *oci_streaming.StreamAdminClient
+	Res    *oci_streaming.GetStreamResponse
+}
+
+func (s *StreamingStreamDataSourceCrud) VoidState() {
+	s.D.SetId("")
+}
+
+func (s *StreamingStreamDataSourceCrud) Get() error {
+	request := oci_streaming.GetStreamRequest{}
+
+	if streamId, ok := s.D.GetOkExists("stream_id"); ok {
+		tmp := streamId.(string)
+		request.StreamId = &tmp
+	}
+
+	request.RequestMetadata.RetryPolicy = getRetryPolicy(false, "streaming")
+
+	response, err := s.Client.GetStream(context.Background(), request)
+	if err != nil {
+		return err
+	}
+
+	s.Res = &response
+	return nil
+}
+
+func (s *StreamingStreamDataSourceCrud) SetData() error {
+	if s.Res == nil {
+		return nil
+	}
+
+	s.D.SetId(*s.Res.Id)
+
+	if s.Res.CompartmentId != nil {
+		s.D.Set("compartment_id", *s.Res.CompartmentId)
+	}
+
+	if s.Res.DefinedTags != nil {
+		s.D.Set("defined_tags", definedTagsToMap(s.Res.DefinedTags))
+	}
+
+	s.D.Set("freeform_tags", s.Res.FreeformTags)
+
+	if s.Res.LifecycleStateDetails != nil {
+		s.D.Set("lifecycle_state_details", *s.Res.LifecycleStateDetails)
+	}
+
+	if s.Res.MessagesEndpoint != nil {
+		s.D.Set("messages_endpoint", *s.Res.MessagesEndpoint)
+	}
+
+	if s.Res.Name != nil {
+		s.D.Set("name", *s.Res.Name)
+	}
+
+	if s.Res.Partitions != nil {
+		s.D.Set("partitions", *s.Res.Partitions)
+	}
+
+	if s.Res.RetentionInHours != nil {
+		s.D.Set("retention_in_hours", *s.Res.RetentionInHours)
+	}
+
+	s.D.Set("state", s.Res.LifecycleState)
+
+	if s.Res.TimeCreated != nil {
+		s.D.Set("time_created", s.Res.TimeCreated.String())
+	}
+
+	return nil
+}